package com.example.demo.rocketmq;

import org.apache.rocketmq.client.producer.SendResult;

/**
 * @author lance@oigcn.com
 * @version 1.0
 * @description
 * @date 2021-04-12 16:56
 **/
public interface MQSender {

    /**
     * 发送消息
     *
     * @param message 消息信息
     * @param topic   主题
     * @return 发送结果
     */
    SendResult sendMessage(Object message, String topic);

    /**
     * 发送消息
     *
     * @param message 消息信息
     * @param topic   主题
     * @param tags    主题的标签
     * @return 发送结果
     */
    SendResult sendMessage(Object message, String topic, String tags);
}
